package org.alex.mqtt.common.retain;


import org.alex.mqtt.common.bus.model.DeviceMessage;

import java.util.List;

/**
 * 保存消息处理器
 */
public interface RetainMessageHandler {

    /**
     * 获取所有保存消息
     */
    List<DeviceMessage> getAllRetainMessage();

    /**
     * clear 某一topic的保存消息
     */
    void clearRetainMessage(String topic);

    /**
     * 保存消息到消息处理器
     */
    void storeRetainMessage(DeviceMessage deviceMessage);
}
